Deno Queues

code:typescript

const kv = await Deno.openKv(":memory:");

// メッセージを追加します。

const res = await kv.enqueue({ id: 1, payload: "foo" });

assert(res.ok);

let message;

// キューを購読します

const listenPromise = kv.listenQueue((_message) => {

message = _message;

});

kv.close();

await listenPromise; // closeするとresolveされます

console.info(message);

// Output: { id: 1, payload: "foo" }

ライブラリ/フレームワーク

リンク